package org.dtp;

import java.util.Collection;
import java.util.HashMap;
import java.util.Map;

/**
 * 线程池工具类
 * {@link org.dtp.DtpExecutor}
 */
public class DtpUtil {
    public static Map<String, DtpExecutor> map =new HashMap<String,DtpExecutor>();

    /**
     * 获取所有线程池
     * @return 所有线程池
     */
    public static Collection<DtpExecutor> getAllDtpExecutor(){
        return map.values();
    }

    /**
     * 获取所有线程池名称
     * @return 所有线程池名称
     */
    public static Collection<String> getAllDtpExecutorName(){
        return map.keySet();
    }

    /**
     * 根据线程池名称获取线程池
     * @param poolName
     * @return 动态线程池
     */
    public static DtpExecutor getDtpExecutor(String poolName){
        return map.get(poolName);
    }

    /**
     * 添加线程池
     * @param poolName
     * @param dtpExecutor
     */
    public static void put(String poolName,DtpExecutor dtpExecutor){
        map.put(poolName,dtpExecutor);
    }
}
